package com.ysw.java_api.partioner;

import org.apache.kafka.clients.producer.Partitioner;
import org.apache.kafka.common.Cluster;

import java.util.Map;

/**
 * @ClassName MyPartioner
 * @Description 自定义指定分区，这个一般是不需要自己去定义的，使用默认的就可以
 * @Author ysw
 * @Date 2021/12/12 21:03
 */
public class MyPartioner implements Partitioner {
    @Override
    public int partition(String s, Object o, byte[] bytes, Object o1, byte[] bytes1, Cluster cluster) {
        // 这里可以按照自己的业务进行分区
        return 0;
    }

    @Override
    public void close() {

    }

    @Override
    public void configure(Map<String, ?> map) {

    }
}